package cn.getech.data.development.service;

import cn.getech.data.development.model.req.realtimequeue.RealtimeQueueListReq;
import com.baomidou.mybatisplus.extension.service.IService;
import cn.getech.data.intelligence.common.utils.PageUtils2;
import cn.getech.data.development.entity.RealtimeQueueEntity;

import java.util.Map;

/**
 * 调度实时队列
 *
 * @author qiuxinglei
 * @email qiuxinglei@gmail.com
 * @date 2020-09-03 10:57:49
 */
public interface RealtimeQueueService extends IService<RealtimeQueueEntity> {

    PageUtils2<RealtimeQueueEntity> queryPage(Map<String, Object> params);

    PageUtils2<RealtimeQueueEntity> queryPage(RealtimeQueueListReq req);

    void cheackQueue(Long queueId);
}

